从JetStream中删除特定主题或创建多少个主题

我认为您正在寻找的是您的流的“WorkingQueue”保留策略，一旦消息被订阅者发送并确认到流上的使用者，它就会从流中删除消息。

因此，例如，在“orders.new”上发布了新的订单请求。并且您有一个包含“WorkingQueue”保持策略的流，用于侦听主题'orders.new.*‘，并且工作进程订阅了一个(持久的、拉出的)使用者。工作进程从流中提取新的订单，一旦成功完成处理，它们就会对消息进行包装，并将其从请求流中删除。一定要根据您的处理时间调整消费者的“AckWait”和/或使用“给我更多时间处理”确认。

您可以重复此模式来创建工作流(例如，消息在“orders.new”流中，另一条消息被发布到“orders.processing”流中，并由此从“orders.new”中添加并删除)，或者执行长时间的请求回复(例如提交作业)，例如将答复发布到“结果”的地方。并且您定义了一个侦听“结果.*”(工作队列或时间限制)的流，您可以让客户端使用对“结果”的临时消费者筛选来等待其订单处理的结果。